package cn.gwm.flink.streaming.constant;

import cn.gwm.utils.ConfigLoader;

/**
 * @ClassName FaultToleranceConstant
 * @Description 故障容错常量
 * @Author LiangGuang
 * @Date 2023/06/19 14:55
 */
public class FaultToleranceConstant {

    public static final String FLINK_JOB_NAME = "flinkJobName";


    /**
     * 检查点路径  CHECKPOINT_URL + jobName
     */
    public static final String CHECKPOINT_URL = ConfigLoader.get("hdfsUri") + "/flink-checkpoints/";
    /**
     * 保存点路径  SAVEPOINT_URL + jobName
     * 保存点的使用，注意所有算子给唯一的 uid
     */
    public static final String SAVEPOINT_URL = ConfigLoader.get("hdfsUri") + "/flink-savepoints/";

}
